package com.rj.data.task;

import com.rj.data.sink.Sink;
import com.rj.data.source.Source;
import lombok.Data;

import java.util.List;

/**
 * 任务基类
 *
 * @param <T>
 */
@Data
public abstract class Task<T> {

    protected Source source;
    protected List<Sink> sinks;

    public Task(Source source, List<Sink> sinks) {
        this.source = source;
        this.sinks = sinks;
    }


    public abstract T runTask() throws Exception;
}
